package cororpc

// RPCClient 作为rpc的调用方,接收别的模块的返回
type RPCClient struct {
	// 别的协程异步返回的队列
	ChanAsyncRet chan *ReturnInfo
	// TODO 或者会有同步等返回的那种
}

func NewClient() *RPCClient {
	return &RPCClient{
		ChanAsyncRet: make(chan *ReturnInfo),
	}
}

// OnReply 别的协程的返回
func (c *RPCClient) OnReply(ri *ReturnInfo) {
	if ri.cb != nil {
		ri.cb(ri.err, ri.ret)
	}
}
